package com.bigdata.spark.sql

import org.apache.spark.SparkConf
import org.apache.spark.sql._

object Spark05_SparkSQL_Hive {
  def main(args: Array[String]): Unit = {
    System.setProperty("HADOOP_USER_NAME", "root")
    // TODO 创建SparkSQL的运行环境
    val sparkConf = new SparkConf().setMaster("local[*]").setAppName("sparkSQL")
    val spark = SparkSession.builder().enableHiveSupport().config(sparkConf).getOrCreate()

    // 使用sparkSQL连接外置的hive
    // 1. 拷贝hive-site.xml文件到classpath下
    // 2. 启用hive支持
    // 3. 增加对应的依赖关系（包含MySQL的驱动）
    spark.sql("show tables").show


    // TODO 关闭环境
    spark.close()

  }
}
